package com.kloooong.top.customer;


import com.alibaba.fastjson.JSONObject;
import com.dingteam.push.api.channel.MarketOrderInput;
import com.kloooong.top.message.OpenSyncBizDataDO;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

//@Component
//@EnableBinding(MarketOrderInput.class)
public class MarketOrderCustomer {

//    @StreamListener(target = MarketOrderInput.INPUT ,condition = "headers['syncAction']=='push_demo_test' and headers['suiteId']=='100001' ")
//    public void userVip(OpenSyncBizDataDO openDO) {
//        System.out.println("suitId push data is coming 。。。");
//        System.out.println("data："+ JSONObject.toJSONString(openDO));
//    }

}
